package com.mwy.springbootrabbitmq.mq.pro;

/**
 * 测试方法
 */
public class ClientTest {
    public static void main(String[] args) throws InterruptedException {
        //被观察者
        BeMonitoredImpl beMonitored = new BeMonitoredImpl();
        //为被观察者添加观察者对象
        beMonitored.addMonitor(new MonitorImpl());

        beMonitored.haveFun();

        beMonitored.haveBreakfast();

    }
}
